package com.boco.job;

import java.util.Arrays;
import java.util.List;

import com.dangdang.ddframe.job.api.ShardingContext;
import com.dangdang.ddframe.job.api.dataflow.DataflowJob;

public class DataflowJobDemo implements DataflowJob {

	@Override
	public List fetchData(ShardingContext shardingContext) {
		return Arrays.asList("1","2","3");
	}

	@Override
	public void processData(ShardingContext shardingContext, List data) {
		
	}

}
